package com.example.springboottest.example.blockqueue;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

/**
 * BlockingQueue 可以定义为限定容量的队列，它有一个 remainingCapacity容量值，超出此容量，便无法无阻塞地 put 额外的元素。
 * 也可以定义为没有容量限制的队列，没有容量约束的 BlockingQueue 总是报告 Integer.MAX_VALUE 的剩余容量。
 * <p>
 * 1.添加类方法
 * add(E e)：添加成功则返回true，失败就抛出 IllegalStateException异常       非阻塞模式
 * offer(E e)：成功则返回true，如果此队列已满，就返回fals                    非阻塞模式
 * put(E e)：将元素添加至此队列的尾部，如果该队列已满，就 一直阻塞              阻塞模式
 * 2.删除类方法
 * poll()：获取并移除此队列的头元素，若队列为空，则返回 null                   非阻塞模式
 * take()：获取并移除此队列的头元素，若没有元素，则一直阻塞                     阻塞模式
 * remove(Object o)：移除指定元素，成功则返回true，失败则返回false            非阻塞模式
 * 3.获取元素类方法
 * element()：获取但不移除此队列的头元素，没有元素则抛出异常
 * peek()：获取但不移除此队列的头元素，若队列为空，则返回 null
 */
public class BlockingQueueTest {
    public static void main(String[] args) {
        final BlockingQueue queue = new ArrayBlockingQueue(3);
        for (int i = 0; i < 2; i++) {
            new Thread() {
                public void run() {
                    while (true) {
                        try {
                            Thread.sleep((long) (Math.random() * 1000));
                            System.out.println(Thread.currentThread().getName() + "准备放数据!");
                            queue.add(1);
                            System.out.println(Thread.currentThread().getName() + "已经放了数据，" + "队列目前有" + queue.size() + "个数据");
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }

            }.start();
        }
        new Thread() {
            public void run() {
                while (true) {
                    try {
                        //将此处的睡眠时间分别改为100和1000，观察运行结果
                        Thread.sleep(1000);
                        System.out.println(Thread.currentThread().getName() + "准备取数据!");
//                        queue.take();
                        System.out.println(Thread.currentThread().getName() + "已经取走数据，" +
                                "队列目前有" + queue.size() + "个数据");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }.start();
    }
}